package com.econ.powercloud.ems.timing.report.prometheus.callback;

import com.econ.powercloud.console.facade.utils.CacheKeyUtils;
import com.econ.powercloud.ems.common.util.JacksonExtUtil;
import com.econ.powercloud.ems.util.AsyncHttpClientUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
public class PrometheusKafkaStatusCallback extends AbstractPrometheusSingleDataCallback implements AsyncHttpClientUtil.StringFutureCallback {

    final private String category = "kafka";

    final private String item = "status";

    @Override
    public void success(String content) {
        dealWithPrometheusCallbackData(content);
    }

    @Override
    String getCategory() {
        return this.category;
    }

    @Override
    String getItem() {
        return this.item;
    }
}
